package cn._51doit.flink.day11;

import org.apache.flink.table.functions.AggregateFunction;


public class MySumAggFunction2 extends AggregateFunction<Long, Long> {


    @Override
    public Long getValue(Long aLong) {
        return aLong;
    }

    @Override
    public Long createAccumulator() {
        return new Long(0);
    }

    public void accumulate(Long accumulator, Long in) {
        accumulator += in;
    }
}
